package club.vann.mock.kafka;

import club.vann.mock.common.exception.ProtobufCaseException;
import java.util.function.Consumer;
import org.apache.kafka.clients.consumer.ConsumerRecord;

public class AbsKafkaService implements KafkaService {
  @Override
  public void register(
      String topic, Consumer<ConsumerRecord<String, byte[]>> consumerRecordConsumer) {
    KafkaConsumer.registerConsumer(topic, consumerRecordConsumer);
  }

  @Override
  public <T> T parseFrom(byte[] bytes, Class<T> clazz) throws ProtobufCaseException {
    return null;
  }
}
